package com.feihong.txgw.utils.manage;

import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;

/**
 * @Author wangziheng
 * @ProjectName txgw_app
 * @ClassName RxManager
 * @package com.feihong.txgw.utils.manage
 * @data 2018/5/2 11:32
 * @Describe
 * @Change
 */
public class RxManager {
    /**
     * 管理订阅者者
     */
    private CompositeDisposable mCompositeDisposable = new CompositeDisposable();

    public void register(Disposable d) {
        mCompositeDisposable.add(d);
    }

    public void unSubscribe() {
        mCompositeDisposable.dispose();// 取消订阅
    }

    public void unSubscribe(Disposable d){
        mCompositeDisposable.remove(d);
    }

}
